logstash消費Kafka消息，報錯：javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,i

當input里面有多個kafka輸入源時，client_id => "logstash-1-1"，必須添加且需要不同， 否則會報錯javax.management.InstanceAlread ...